d74b125265635246465702c3f7a6f8cda33f310c,src/test/java/com/rabbitmq/client/test/BrokerTestCase.java,BrokerTestCase,newConnectionFactory,#,63
Before Change
protected ConnectionFactory newConnectionFactory() {
ConnectionFactory connectionFactory = new ConnectionFactory();
if(nio()) {
connectionFactory.useNio();
this.nioExecutor = Executors.newFixedThreadPool(5);
connectionFactory.setNioParams(new NioParams().setNioExecutor(this.nioExecutor));
} else {
connectionFactory.useBlockingIo();
this.nioExecutor = null;
After Change
protected ConnectionFactory newConnectionFactory() {
ConnectionFactory connectionFactory = new ConnectionFactory();
if(nio()) {
connectionFactory.useNio();
} else {
connectionFactory.useBlockingIo();
}